/**
 * Created by Administrator on 2017/5/15.
 */

var pipe = require('../models/Pipe');



function getinq(key,callback) {
    pipe.enQueue({key: key, callback: callback});
}
console.time('a')
// enq
for(let i=0;i<5000;i++) {
    getinq(i,function (d) {
        console.log(i+'  ============inq',d)
        if(i==4999) {
            console.timeEnd('a')
        }
    })
    console.log('i=',i)
}

pipe.start();
console.log('pipe start')



